import org.apache.spark.SparkConf;
import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.api.java.function.Function;
import org.apache.spark.sql.execution.vectorized.ColumnVector;
import org.stringtemplate.v4.ST;

import javax.rmi.CORBA.Util;
import java.util.*;

public class Main {

    public static void main(String[] args) {
//
//        JavaSparkContext  sc = new JavaSparkContext("local","SparkTest");
//        JavaRDD<String> rdd = sc.textFile("e:/hellowSpark.txt");
//        List<String> list = new ArrayList<String>();
//        list.add("a, b, c, d, e");
//        list.add("1, 2, 3 ,4 , 5");
//        JavaRDD<String> input = sc.parallelize(list);
//        JavaRDD<String []> mapRdd = input.map(new Function<String, String[]>() {
//            @Override
//            public String[] call(String s) throws Exception {
//                return s.split(",");
//            }
//        });







        System.out.println("Hello World!");
    }
}
